bfcb69a2a6a4f82bdec21c8811ac72460a0b5611,hazelcast/src/main/java/com/hazelcast/mapreduce/impl/task/JobSupervisor.java,JobSupervisor,cancelAndNotify,#,168
Before Change
TrackableJobFuture future = jobTracker.unregisterTrackableJob(jobId);
jobTracker.unregisterMapCombineTask(jobId);
jobTracker.unregisterReducerTask(jobId);
mapReduceService.destroyJobSupervisor(this);
if (future != null) {
After Change
if (mapCombineTask != null) {
mapCombineTask.cancel();
}
ReducerTask reducerTask = jobTracker.unregisterReducerTask(jobId);
if (reducerTask != null) {
reducerTask.cancel();
}
mapReduceService.destroyJobSupervisor(this);